package com.ylr.config.rocket;


import com.ylr.common.enums.MessageChannel;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 数据的接收
 */
public interface Sink {
    String INPUT = "exchange_trade_in";
    String INPUT2 = "cancel_order_in";
    /**
     * 交易数据的输入
     * @return
     */
    @Input(Sink.INPUT)
    SubscribableChannel exchangeTradeIn() ;



    /**
     * 取消订单的输入
     * @return
     */
    @Input(Sink.INPUT2)
    SubscribableChannel cancelOrderIn() ;
}
